package interfaces

import (
	"octopus/internal/domain/entities"
)

// TaskManager 定义了任务管理的接口
type TaskManager interface {
	CreateTask(id string) *entities.Task
	UpdateTaskStatus(task *entities.Task, status entities.TaskStatus)
	NotifyTaskCompletion(task *entities.Task, notify func(task *entities.Task))
	SetEventBus(eventBus EventBus)
}

// TaskNotifier 定义了任务通知的接口
type TaskNotifier interface {
	NotifyTaskCompletion(task *entities.Task, notify func(task *entities.Task))
}

